using Org.Apache.Rocketmq;

namespace RocketMQ.Test;

public class CustomMessageListener : IMessageListener
{
    public ConsumeResult Consume(MessageView messageView)
    {
        // Handle the received message and return consume result.
        // messageVie
        Console.WriteLine($"Consume message={messageView}");
        return ConsumeResult.SUCCESS;
    }
}